#ifndef APP_MQTT_H
#define APP_MQTT_H

#define ADDRESS "tcp://192.168.226.1:1883"
#define CLIENTID "8c45d688-0835-4111-bd2e-a1997d2c2099"
#define TOPIC_PULL "pull" // 接收消息的主题
#define TOPIC_PUSH "push" // 发送消息的主题
#define QOS 1
#define TIMEOUT 10000L

// 初始化mqtt客户端
int app_mqtt_init(void);

// 发送mqtt消息
int app_mqtt_send(char *data, int len);

// 注册接收消息的回调函数
void app_mqtt_registRecvCallback(int (*callback)(char *, int));

// 关闭mqtt客户端
void app_mqtt_close(void);

#endif // APP_MQTT_H